const { mysql } = require('../../mysql')

// 添加收藏
async function addCollect(ctx) {
    const { openId, goodsId } = ctx.request.body
    // console.log(openId, goodsId);
    // 判断当前用户是否已经收藏当前商品
    const iscollect = await mysql('nideshop_collect').where({
        'user_id': openId,
        'value_id': goodsId
    }).select()
    // 没有收藏则插入数据
    if (iscollect.length == 0) {
        await mysql('nideshop_collect').insert({
            'user_id': openId,
            'value_id': goodsId
        })
        ctx.body = {
            data: 'collected'
        }
    } else {
        // 否则移除数据
        await mysql('nideshop_collect').where({
            'user_id': openId,
            'value_id': goodsId
        }).del()
        ctx.body = {
            data: 'uncollect'
        }
    }
}

module.exports = {
    addCollect
}